package com.example.demozmq.zmq;

import org.zeromq.ZMQ;

public class ZmqPullServer {

    public static void main(String[] args) {

        ZMQ.Context context = ZMQ.context(1);
        ZMQ.Socket socket = context.socket(ZMQ.PULL);

        socket.bind("ipc://fjs");

        while (true) {
            byte[] data = socket.recv();
            System.out.println("拉取的数据：" + new String(data));
        }
    }

}
